/*      
 * 模块编号  
 * 功能描述 
 * 文件名 MessageProviderImpl.java 
 * 作者 王磊 
 * 编写日期 2022年03月01日 
 */
package wl.demo.springcloud.service.impl;

import java.util.UUID;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.MessageChannel;

import wl.demo.springcloud.service.IMessageProvider;

@EnableBinding(Source.class)
public class MessageProviderImpl implements IMessageProvider{
	@Autowired
	private MessageChannel output;

	@Override
	public String send() {
		String serial = UUID.randomUUID().toString();
        this.output.send(MessageBuilder.withPayload(serial).build()); // 创建并发送消息
        System.out.println("***serial: "+serial);

        return serial;
	}
}
